package com.at.bigdata.spark.sql

import org.apache.spark.SparkConf
import org.apache.spark.sql.{SaveMode, SparkSession}

/**
 *
 * @author cdhuangchao3
 * @date 2023/5/27 8:05 PM
 */
object Spark05_SparkSql_Hive {
//  System.setProperty("HADOOP_USER_NAME", "hdfs")
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("operator")
    val spark = SparkSession.builder()
      .enableHiveSupport()
      .config(sparkConf)
      .getOrCreate()

    // 使用spark连接外置hive
    // 1、拷贝hive-site.xml到classpath目录下
    // 2、启用hive支持
    // 3、增加对应依赖关系（包含MySql驱动）
    spark.sql("show databases").show

    spark.close();
  }

}
